def get_test2():
    from re_common.baselibrary.utils.basepika import  BasePika


    basepika = BasePika()

    basepika.set_default()
    basepika.connect()
    basepika.create_channel()
    basepika.queue_declare(queue="cnkijournal_download_service", durable=True)
    basepika.basic_qos(3)
    basepika.set_get_msg_callback(routing_key="cnkijournal_download_service", auto_ack=False)
    basepika.start_get_msg()


get_test2()